653d344b2808d997d57609207a001c596f5babda,core/src/main/java/io/undertow/channels/DetachableStreamSourceChannel.java,DetachableStreamSourceChannel,read,#ByteBuffer[]#number#number#,189

Before Change


    }

    public long read(final ByteBuffer[] dsts, final int offset, final int length) throws IOException {
        if (isFinished() && minusOneReturned) {
            return -1;
        }
        long ret = delegate.read(dsts, offset, length);
        if (ret == -1) {
            minusOneReturned = true;
        } else if (isFinished()) {
            runReadListener();
        }
        return ret;
    }

    public void wakeupReads() {

After Change


    }

    public long read(final ByteBuffer[] dsts, final int offset, final int length) throws IOException {
        if (isFinished()) {
            return -1;
        }
        return delegate.read(dsts, offset, length);
    }

    public void wakeupReads() {